package com.example.klinemqflink.utils;

import com.example.klinemqflink.model.MarketData;
import org.apache.flink.util.OutputTag;

public class Constant {
    public static final OutputTag<MarketData> lateDataOutputTag = new OutputTag<MarketData>("late-data") {};

}
